package com.at.functions5;

import com.at.bean.WaterSensor;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author huangchao E-mail:fengquan8866@163.com
 * @version 创建时间：2024/9/25 11:33
 */
public class MapFunctionImpl1 implements MapFunction<WaterSensor, String> {

    private static final long serialVersionUID = -4682322908252552046L;

    @Override
    public String map(WaterSensor value) throws Exception {
        return value.getId();
    }
}
